package com.hr.reactive.flux;

import com.hr.reactive.common.Utils;
import reactor.core.publisher.Flux;

/**
 * 空方法和错误
 * @author Administrator
 */
public class Lec05FluxEmptyError {
    public static void main(String[] args) {
        Flux.empty().subscribe(Utils.subscriber());
        Flux.error(new RuntimeException("test"))
                        .subscribe(Utils.subscriber());
        Utils.sleepSeconds(5000);
    }
}
